Goals ⚽

Introduce a new FueledSwiftConcurrency target providing utilities for Swift's async/await concurrency model

Backwards-compatibility:

⚠️ 🚨 THIS WILL BREAK THE IMPORTS OF THE NEW TARGETS BECAUSE THEY DON'T HAVE UTILS IN THEM (e.g FueledUtilsCore -> FueledCore) 🚨⚠️

Implementation Details 🚧

• Remove the Utils word from all the targets!
• Created FueledSwiftConcurrency as a new library target with dependencies on AsyncAlgorithms and ConcurrencyExtras

Core Utilities Added:

• AsyncSemaphore - An async-compatible counting semaphore for controlling concurrent access to shared resources. Supports both regular and cancellation-aware waiting.
• CurrentValueAsyncSubject - A thread-safe subject that holds a current value and broadcasts changes, similar to Combine's CurrentValueSubject but designed for async/await.
• BroadcastStream - A thread-safe broadcast stream that emits values to multiple subscribers, with optional replay of the last emitted value.
• BufferedStream - A buffered async stream that stores emitted values and replays them to new consumers, useful for late subscribers.
• AsyncCache - An actor-based asynchronous cache for storing key-value pairs with lazy computation and thread-safe access.

AsyncSequence Extensions:

• takeUntil(_:) - Takes elements from a sequence until a condition is met
• timeout(for:clock:tolerance:throwing:alwaysFinishAfterTimeout:) - Applies timeout behavior to async sequences with configurable error handling

AsyncStream Extensions:

• timeout(after:) - Creates a stream that completes after a specified duration
• flatMapOptional(_:) - Transforms elements into optional streams and flattens the result
• promoteOptional() - Wraps each emitted value in an optional
• single(value:) - Static factory for creating a stream that emits a single value

Testing Details 🔍

All tests have been added ✅